package org.qiyu.live.im.router.provide.cluster;

import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.cluster.Cluster;
import org.apache.dubbo.rpc.cluster.Directory;

/**
 * @Description: 基于Cluster去做spi扩展,实现根据roc上下文来选择具体请求的机器
 * @Author: 张广焱
 * @Date: 2023-12-10 2:41
 */
public class ImRouterCluster implements Cluster {
    @Override
    public <T> Invoker<T> join(Directory<T> directory, boolean buildFilterChain) throws RpcException {
        return new  ImRouterClusterInvoker(directory);
    }
}
